package com.liang.blog.reception.utils;

import com.liang.blog.model.BlogUser;

import javax.websocket.Session;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Author：YanWenLiang
 * @Date:2024-05-02-9:16
 */
public class CurPool {
    //存放websocket的session对象，发消息时使用，key:userID,value:Session
    public static Map<Long, Session> sessionPool = new ConcurrentHashMap<>();

    //存放当前用户的 SessionList对象（即 当前用户的正在与谁会话） key:userId,value:SessionList
    public static Map<Long, String> sessionListIdPool = new ConcurrentHashMap<>();

}
